home *** CD-ROM | disk | FTP | other *** search
/ Network Support Library / RoseWare - Network Support Library.iso / apidev / server.arc / SERVER.C < prev    next >
Text File  |  1989-11-29  |  5KB  |  126 lines
  1. /*------------------------------------------------* 
  2.  *     Named Pipes server                         * 
  3.  *                                                * 
  4.  *     Written by: Stephen T. Bunch               * 
  5.  *                 API Development                * 
  6.  *                                                * 
  7.  *     Date:       July 11, 1989                  * 
  8.  *                                                * 
  9.  *------------------------------------------------*/ 
  10. #include   <stdio.h> 
  11. #define    INCL_BASE 
  12. #include   <os2.h> 
  13. #include   <nwcalls.h> 
  14. #include   <malloc.h> 
  15. #include   "server.h" 
  16.  
  17. #define    CLIENT_NUM    4       /* number of threads to create (potentially the 
  18.                                     number of concurrent clients also) */ 
  19. #define    STACK_SIZE    2000    /* stack size for each thread */ 
  20. #define    PIPENAME      "\\PIPE\\TLAPIPE" 
  21.  
  22. HPIPE    pipeHandle[CLIENT_NUM]; 
  23.  
  24.  
  25. /*----------------------------------------------------------------------*/ 
  26. main(int argc,char *argv[]) 
  27. { 
  28.     int err, i; 
  29.     void far Receiver();            /* address of thread routine */ 
  30.     TID threadID[CLIENT_NUM];       /* thread IDs */ 
  31.     USHORT far *stackPtr;           /* ptr to thread's stack */ 
  32.  
  33.     TLAReadIndex(); 
  34.     printf("\tWelcome to the TLA server program.\n"); 
  35.     printf("\tEnter 'down' to down this server.\n\n"); 
  36.  
  37.     /* spin off the threads which will each initiate an instance */ 
  38.     for (i=0; i<CLIENT_NUM; i++) { 
  39.         stackPtr = (WORD far *)malloc(STACK_SIZE) + (char)STACK_SIZE; 
  40.         /* pass a parameter by putting the client number on the stack */ 
  41.         stackPtr--; 
  42.         *stackPtr = i; 
  43.         err = DosCreateThread(Receiver, &threadID[i], (char far *)stackPtr); 
  44.         if (err) 
  45.             printf("DosCreateThread Error : %d\n", err); 
  46.     } 
  47.     CleanUp(); 
  48. } 
  49.  
  50. /*----------------------------------------------------------------------* 
  51.  * CleanUp performs the exiting procedures, disconnecting and closing   * 
  52.  * the pipes.                                                           * 
  53.  *----------------------------------------------------------------------*/ 
  54. CleanUp() 
  55. { 
  56.     BYTE response[20]; 
  57.     int err, i; 
  58.  
  59.     /*  wait until 'down' is indicated  */ 
  60.     do { 
  61.         gets(response); 
  62.     } while (strcmp(response, "down") != 0); 
  63.     TLACloseIndex(); 
  64.  
  65.     /* disconnect all instances of the pipe */ 
  66.     DosEnterCritSec(); 
  67.     for (i=0; i<CLIENT_NUM; i++){ 
  68.         err = DosDisConnectNmPipe(pipeHandle[i]); 
  69.         if (err) 
  70.             printf("DosDisConnectNmPipe (Client %d) Error : %d\n", i, err); 
  71.     } 
  72.  
  73.     /* close the pipe handels */ 
  74.     for (i=0; i<CLIENT_NUM; i++){ 
  75.         err = DosClose(pipeHandle[i]); 
  76.         if (err) 
  77.             printf("DosClose (Client %d) Error : %d\n", i, err); 
  78.     }     
  79.     DosExitCritSec(); 
  80.     DosExit(1, 0); 
  81. } 
  82.  
  83. /*----------------------------------------------------------------------* 
  84.  * Receiver is the server side of the IPC connection.  It makes, reads, * 
  85.  * writes, and closes the pipe until 'down' is entered.                 * 
  86.  *----------------------------------------------------------------------*/ 
  87. void far Receiver(ClientNum) 
  88. int ClientNum; 
  89. { 
  90.     USHORT openMode = 0x0002;                /* Duplex pipe */ 
  91.     USHORT pipeMode = 0x0504;                /* Number of instances allowed */ 
  92.     LONG timeOut = 0;                        /* default time out value */ 
  93.     USHORT bytesWritten, bytesRead; 
  94.     TID threadID; 
  95.     USHORT err; 
  96.     struct COMMBUFFER commBuffer; 
  97.  
  98.     /* create an instance of the named pipe  */ 
  99.     err = DosMakeNmPipe(PIPENAME, &pipeHandle[ClientNum], openMode, pipeMode, 
  100.             sizeof(struct COMMBUFFER), sizeof(struct COMMBUFFER), timeOut); 
  101.     do { 
  102.         /* wait for the user to connect to the named pipe */ 
  103.         err = DosConnectNmPipe(pipeHandle[ClientNum]); 
  104.         printf("DosConnectNmPipe (Client %d) : %d\n", ClientNum, err); 
  105.  
  106.         /* Read from the pipe */ 
  107.         err = DosRead(pipeHandle[ClientNum], &commBuffer, 
  108.                                 sizeof(struct COMMBUFFER), &bytesRead); 
  109.         if (err) 
  110.             printf("DosRead Error : %d\n", err); 
  111.         if ((err = TLAServiceRequest(&commBuffer)) != 0) { 
  112.             strcpy(commBuffer.record.explain,"The TLA requested could not be found"); 
  113.         } 
  114.         err = DosWrite(pipeHandle[ClientNum], &commBuffer, 
  115.                         sizeof(struct COMMBUFFER), &bytesWritten); 
  116.         if (err) 
  117.             printf("DosWrite Error (Client %d) : %d\n", ClientNum, err); 
  118.         DosSleep(500L); 
  119.  
  120.         /*  user end of the pipe has gone away - close this instance  */ 
  121.         err = DosDisConnectNmPipe(pipeHandle[ClientNum]); 
  122.     } while (TRUE); 
  123. } 
  124.  
  125.  
  126.